/**
 * 
 */
package org.textplantform.common.api.mq;

/**
 * @author alex
 *
 */
public interface MessageConsumer<M> {
	void consume(M message);
	void consume(Iterable<M> messages);
}
